package metrics

import (
	streamCtx "gluenet/internal/glue-datasyncer/context"
)

func Metrics(ctx *streamCtx.StreamContext) {
	//ctx.Logger.Debugf("reccive metrics")

	if err := ctx.DB.Prom.WriteData(ctx.RpcContext.Data.Data); err != nil {
		ctx.Logger.Errorf("write data failed %v", err)
		return
	}

	ctx.MetricsChan <- ctx.RpcContext.Data.Data
}
